Al usar kotlin 1.6.10, parece que parallelStream() y asSequence().asStream().parallel() no se comportan de la misma manera. Este último no parece paralelizar. Aquí hay un fragmento de código de ejemplo que demuestra el problema:
import java.util.stream.Collectors.toList import kotlin.streams.asStream import java.util.Calendar fun main() { println("Available processors: ${Runtime.getRuntime().availableProcessors()}") val numbers = (10 downTo 0).toList() println("Using parallelStream:") val start1=System.currentTimeMillis() numbers.parallelStream().map { println("${it} - ${Thread.currentThread().getId()}"); Thread.sleep(100); it }.collect(toList<Int>()) println("Execution time: ${System.currentTimeMillis()-start1}") println("Using asSequence().asStream().parallel():") val start2=System.currentTimeMillis() numbers.asSequence().asStream().parallel().map { println("${it} - ${Thread.currentThread().getId()}"); Thread.sleep(100); it }.collect(toList<Int>()) println("Execution time: ${System.currentTimeMillis()-start2}") }Puede ejecutarlo en el área de juegos de kotlin: https://pl.kotl.in/z3sxKHKvL
la salida es
Available processors: 2 Using parallelStream: 4 - 1 8 - 10 3 - 1 7 - 10 5 - 1 6 - 10 1 - 1 10 - 10 0 - 1 9 - 10 2 - 1 Execution time: 617 Using asSequence().asStream().parallel(): 10 - 1 9 - 1 8 - 1 7 - 1 6 - 1 5 - 1 4 - 1 3 - 1 2 - 1 1 - 1 0 - 1 Execution time: 1105No entiendo la razón de esta diferencia en el comportamiento.
Llamar a stream() o parallelStream() directamente en su Lista significa que, en el fondo, puede llamar a spliterator() en la Lista subyacente directamente y obtener un Spliterator funcional que puede dividir el trabajo en paralelo.
Si convierte la Lista en una Secuencia, ya no tendrá acceso directo a la Lista cuando llame a asStream() en ella. Llamar a asStream() en la secuencia crea una secuencia con un Spliterator ad hoc que no tiene acceso al tamaño de la colección (porque las secuencias no tienen una propiedad de tamaño), por lo que no puede dividir el trabajo para una ejecución paralela.
Básicamente, asSequence() elimina la información de tamaño y la implementación integrada de Spliterator de List.